package com.bestcem.xm.txtanls.dao.impl;//package com.bestcem.xm.txtanls.dao.impl;
//
//import com.bestcem.xm.txtanls.entity.mongo.JoinInfo;
//import com.bestcem.xm.util.CommonUtils;
//import com.bestcem.xm.common.core.uitls.DateUtil;
//import com.mongodb.client.result.DeleteResult;
//import org.bson.types.ObjectId;
//import org.springframework.data.mongodb.core.MongoTemplate;
//import org.springframework.data.mongodb.core.query.Criteria;
//import org.springframework.data.mongodb.core.query.Query;
//import org.springframework.stereotype.Repository;
//
//import javax.annotation.Resource;
//import java.util.List;
//
//import static com.bestcem.xm.txtanls.util.CollectionName.TXTANLS_JOIN_INFO;
//import static com.bestcem.xm.txtanls.util.ColumnConstant.JoinInfo.*;
//
///**
// * @author liheng
// * @version v1.0
// * @date 2021/6/28 14:18
// */
//@Repository
//public class JoinInfoDaoImpl {
//
//    @Resource
//    private MongoTemplate mongoTemplate;
//
//    /**
//     * 查询原话记录id对应的所有原话记录。
//     *
//     * @param projectId 项目id
//     * @param recordIds 原话记录id
//     * @return List<JoinInfoEntity>
//     * @author jy.zhao
//     * @date 2021/5/13 13:58
//     **/
//
//    public List<JoinInfo> listJoinInfos(String projectId, List<String> recordIds) {
//        Query query = new Query();
//        query.addCriteria(Criteria.where(PROJECT_ID).is(new ObjectId(projectId))
//                .andOperator(Criteria.where(RECORD_ID).in(CommonUtils.stringToObjectId(recordIds))));
//        query.fields().include(VIEW_POINT_LIST, RECORD_ID);
//        return mongoTemplate.find(query, JoinInfo.class, TXTANLS_JOIN_INFO);
//    }
//
//    /**
//     * 训练结果保存
//     *
//     * @return String
//     * @author gy.liu
//     * @date 2021/5/14
//     */
//
//    public JoinInfo insertJoinInfo(JoinInfo joinInfoEntity) {
//        joinInfoEntity.setCreatedDate(DateUtil.getMongoDate());
//        joinInfoEntity.setUpdatedDate(DateUtil.getMongoDate());
//        return mongoTemplate.save(joinInfoEntity);
//    }
//
//    /**
//     * 根据原话id查询原话情感分析记录
//     *
//     * @param recordId
//     * @return
//     * @author liheng
//     * @date 2021/5/18 20:54
//     */
//
//    public List<JoinInfo> listByRecordId(String recordId) {
//        Query query = new Query();
//        query.addCriteria(Criteria.where(RECORD_ID).is(new ObjectId(recordId)));
//        query.fields().include(VIEW_POINT_LIST);
//        return mongoTemplate.find(query, JoinInfo.class);
//    }
//
//
//    /**
//     * 删除分析项目下的全部 join info
//     *
//     * @param projectId 项目id
//     * @return The result of a delete operation
//     * @author XiaoYunSong <ys.xiao@idiaoyan.cn>
//     * @date 2021/5/21 14:29
//     */
//
//    public DeleteResult deleteProjectAllJoinInfo(String projectId) {
//        Query query = new Query();
//        query.addCriteria(Criteria.where(PROJECT_ID).is(new ObjectId(projectId)));
//        return mongoTemplate.remove(query, TXTANLS_JOIN_INFO);
//    }
//}
